a26011b7d82f89cc06b6850803d764fd7e9489eb,common/src-mapred/org/pentaho/hadoop/mapreduce/GenericTransReduce.java,GenericTransReduce,close,#,300

Before Change



  @Override
  public void close() throws IOException {
    rowProducer.finished();

    // Stop the executor if any is defined...
    if ( isSingleThreaded() && executor != null ) {

After Change



  @Override
  public void close() throws IOException {
    if ( rowProducer != null ) {
      rowProducer.finished();
    }
    // Stop the executor if any is defined...
    if ( isSingleThreaded() && executor != null ) {